package com.netty;

import com.netty.dto.Message;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleChannelInboundHandler;

/**
 * @author CHL
 * @ClassName: ReceiverMessageHandler
 * @Description: 消费端消费消息
 * @date 2022/12/30 16:25
 * @Version 1.0
 */

public class ReceiverMessageHandler extends SimpleChannelInboundHandler<Message> {

    @Override
    protected void channelRead0(ChannelHandlerContext channelHandlerContext, Message message) throws Exception {
        System.out.println("消费端获取到消息：" + message);
    }

}
